2c9848214ad9782e3afe637193c0984d16ff49a1,src/main/java/net/jodah/recurrent/Recurrent.java,Recurrent,future,#Callable#RetryPolicy#Scheduler#,137
Before Change
public static <T> java.util.concurrent.CompletableFuture<T> future(
Callable<java.util.concurrent.CompletableFuture<T>> callable, RetryPolicy retryPolicy, Scheduler scheduler) {
final java.util.concurrent.CompletableFuture<T> response = new java.util.concurrent.CompletableFuture<T>();
call(AsyncCallable.ofFuture(callable), retryPolicy, scheduler, RecurrentFuture.of(response, scheduler, null), null);
return response;
}
After Change
@Override
@SuppressWarnings("unchecked")
public <T> CompletableFuture<T> future(Callable<CompletableFuture<T>> callable) {
java.util.concurrent.CompletableFuture<T> response = new java.util.concurrent.CompletableFuture<T>();
call(AsyncContextualCallable.ofFuture(callable),
RecurrentFuture.of(response, scheduler, (Listeners<T>) listeners));
return response;
}